package LogServer

import LogServer.spark.streaming.SparkStreaming


/**
  *  Flume + Kafka + SparkStreaming + MongoDB Project
  *
  */
object App extends Serializable{
  def main(args: Array[String]) {
    println("Start to run LogServer")
    val ssc = new SparkStreaming()
    ssc.startJob()
  }
}
